-
Notifications
You must be signed in to change notification settings - Fork 287
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
sink/(cdc): Support multi-table DDL dispatching for MQ sink #5329
Conversation
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by submitting an approval review. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What a big PR, is it possible for us to split the drop table and rename table? Also could you please resolve conflicts before continuing? Thanks!
df94013
to
f7235bc
Compare
The conflicts have been resolved. This PR have bunch of ut modification. But the core logic modification is small. |
Codecov Report
Flags with carried forward coverage won't be shown. Click here to find out more. @@ Coverage Diff @@
## master #5329 +/- ##
================================================
+ Coverage 56.1240% 56.2234% +0.0994%
================================================
Files 522 529 +7
Lines 65325 69809 +4484
================================================
+ Hits 36663 39249 +2586
- Misses 25094 26815 +1721
- Partials 3568 3745 +177 |
/run-all-tests |
/run-all-tests |
/run-all-tests |
2 similar comments
/run-all-tests |
/run-all-tests |
/run-kafka-integration-test |
/run-all-tests |
1 similar comment
/run-all-tests |
/run-kafka-integration-test |
/run-all-tests |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: b35140f
|
/run-all-tests |
/run-verify |
/merge |
This pull request has been accepted and is ready to merge. Commit hash: a90db0a
|
/run-verify |
What problem does this PR solve?
Issue Number: ref #4423
What is changed and how it works?
For the DDLs involving more than one table such as
RENAME TABLE
,DROP TABLE
andDROP VIEW
, TiCDC will dispatch the DDL events to the corresponding Kafka topics respectively if the table-level topic dispatch rules are configured.But there exist some subtle difference between
RENAME TABLE
and the other twoDROP
statements.RENAME TABLE
statement, only one DDL job will be generated, so we must parse the DDL events from that job.DROP TABLE
andDROP VIEW
statements, multiple DDL jobs containing different table/view info will be generated for each statement. But the query in those jobs are identical to each other. Thus we must rebuild the correct query.Check List
Tests
Release note